# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dm.dm_whole_decide_duty_base_dt import jms_dm__dm_whole_decide_duty_base_dt


oss__dm_whole_decide_duty_base_dt = BashOperator(
    task_id='oss__dm_whole_decide_duty_base_dt',
    email=['suning@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/dm_whole_decide_duty_base_dt/execute.sh',
    execution_timeout=timedelta(minutes=50),
)

oss__dm_whole_decide_duty_base_dt << [ jms_dm__dm_whole_decide_duty_base_dt ]
